package com.fir.proto.controller;

import com.fir.proto.mqtt.MqttClient;
import com.fir.proto.protobuf.info.MesInfo;
import com.google.protobuf.ByteString;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;


/**
 * @author fir
 */
@Slf4j
@RestController
@RequestMapping("/test")
public class TestController {


    @Resource
    private MqttClient mqttClient;


    @GetMapping("/send")
    public Object pageData() {

        // 初始化MesInfo对象
        MesInfo.Builder mesInfoBuilder = MesInfo.newBuilder();

        // 设置字符串字段
        mesInfoBuilder.setName("测试数据");

        // 设置整数类型字段
        mesInfoBuilder.setInt32Value(32);
        mesInfoBuilder.setInt64Value(64L);
        mesInfoBuilder.setUint32Value(32);
        mesInfoBuilder.setUint64Value(64L);
        mesInfoBuilder.setSint32Value(32);
        mesInfoBuilder.setSint64Value(64L);
        mesInfoBuilder.setFixed32Value(32);
        mesInfoBuilder.setFixed64Value(64L);
        mesInfoBuilder.setSfixed32Value(32);
        mesInfoBuilder.setSfixed64Value(64L);

        // 设置布尔类型字段
        mesInfoBuilder.setBoolValue(true);

        // 设置浮点类型字段
        mesInfoBuilder.setFloatValue(3.14f);
        mesInfoBuilder.setDoubleValue(3.141592653589793);

        // 设置字节类型字段
        mesInfoBuilder.setBytesValue(ByteString.copyFromUtf8("字节字符串"));

        // 设置枚举类型字段
        mesInfoBuilder.setEnumValue(MesInfo.EnumType.TYPE1);

        // 设置映射类型字段
        mesInfoBuilder.putMapValue("key1", 100);
        mesInfoBuilder.putMapValue("key2", 200);

        // 设置内嵌消息类型字段
        MesInfo.NestedMessage.Builder nestedMessageBuilder = MesInfo.NestedMessage.newBuilder();
        nestedMessageBuilder.setNestedField("内嵌字段值");
        mesInfoBuilder.setNestedMessage(nestedMessageBuilder.build());

        // 设置重复字段
        mesInfoBuilder.addRepeatedStrings("字符串1");
        mesInfoBuilder.addRepeatedStrings("字符串2");

        // 构建MesInfo对象
        MesInfo mesInfo = mesInfoBuilder.build();


        // 构建MesInfo对象
//        MesInfo mesInfo = MesInfo.newBuilder()
//                .setName("测试数据")
//                .build();

        mqttClient.send(mqttClient.TEST_MSG, mesInfo.toByteArray());
        return true;
    }

}